#include "App_Mqtt.h"
#include "log/log.h"
#include <unistd.h>


// 定义回调函数
void recv_callback(char *json)
{
    log_debug("收到消息: %s", json);
}

int main(int argc, char const *argv[])
{
    // 1.初始化mqtt
    App_Mqtt_Init();

    // 2.注册回调函数
    App_Mqtt_RegisterCallback(recv_callback);

    // 3.发送消息
    App_Mqtt_SendJson("{\"name\":\"zy\",\"age\":18}");

    sleep(100);

    // 4.断开连接
    App_Mqtt_Deinit();

    return 0;
}
